package com.visionblue.business.ship.util

import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.flow

/**
 * @author: xlh
 * @date: 2020-05-28 5:25 PM
 * @desc:
 */
fun tickerFlow(delayMillis: Long) = flow {
    repeat(Int.MAX_VALUE) {
        emit(it)
        delay(delayMillis)
    }
}